package com.源码分析;

import java.time.Duration;

import reactor.core.publisher.Flux;

public class DelayDemo {

	public static void main(String[] args) throws InterruptedException {
		Flux.just("hello panda1 "+System.currentTimeMillis())
	    .delaySequence(Duration.ofSeconds(2))
	    .subscribe(s -> {
	        System.out.println(s);
	        System.out.println("hello panda2 "+System.currentTimeMillis());
	    });
		System.out.println("hello panda3 "+System.currentTimeMillis());
		Thread.sleep(5000);
	}

}
